#coding:utf-8
from com.utls.pro_env import SQOOP_PATH
import commands 
class SqoopUtil(object):
    '''
    sqoop operation
    '''
    def __init__(self):
        pass
    
    @staticmethod
    def execute_shell(shell):
        
        #将传入的shell命令执行
        status,output = commands.getstatusoutput(SQOOP_PATH + shell)
        if status !=0:
           return None
        else:
           print "success" 
        
        output = str(output).split("\n")
        
        return output